package com.heima.kafka.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ProducerBoot {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;


    @GetMapping("/send")
    public String send() {
        for (int i = 0; i < 5; i++) {
            if (i % 2 == 0) {
                kafkaTemplate.send("itcast-topic-input", "hello boot kafka");
            } else {
                kafkaTemplate.send("itcast-topic-input", "hello itcast");
            }
        }

        return "发送成功";
    }
}